package com.theten52.demo.io.s3;

import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;

/**
 * @author wangjin
 */
public class InboundHandler1 extends ChannelInboundHandlerAdapter {

    @Override

    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        System.out.println("InboundHandler1.channelRead: ctx :" + ctx);

        // 通知执行下一个InboundHandler
        ctx.fireChannelRead(msg);

    }

    @Override

    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {
        System.out.println("InboundHandler1.channelReadComplete");

        ctx.flush();

    }

}
